package com.dduggs.rocketmq.mqtest;

import com.dduggs.rocketmq.MsgSender;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;

/**
 * Created by ChenJiasheng on 2017/10/30.
 */
@Service("memberPointMqService")
public class MemberPointMqServiceImpl implements MemberPointMqService{

    @Resource
    private MsgSender msgSender;

    @Override
    public Object addMemberPoint(String memberCode) {
        return msgSender.sendMessage(memberCode,"cmcp_point","member");
    }
}
